package com.fanxl.flink.datastream.transformation;

import org.apache.flink.api.java.functions.KeySelector;

import java.util.Map;


/**
 * @author Dell
 * @Title:
 * @Description: 请写注释类
 * @date 2022/2/17
 */
public class NameKeySelector implements KeySelector<Map<String, Object>,String> {

    private String properties;

    public NameKeySelector(String properties) {
        this.properties = properties;
    }

    @Override
    public String getKey(Map<String, Object> value) throws Exception {
        return value.get(properties) + "";
    }
}
